package com.hgvip.common;

/**
 * Created by arnold.zhu on 2017/8/7.
 */
public class KafkaParams {

    // 基本参数
    public static final String BOOTSTRAP_SERVERS = "172.16.98.184:9092,172.16.98.185:9092,172.16.98.186:9092";
    public static final String GROUP_ID = "my-consumer1";
    public static final String KEY_DESERIALIZER = "org.apache.kafka.common.serialization.StringDeserializer";
    public static final String VALUE_DESERIALIZER = "org.apache.kafka.common.serialization.StringDeserializer";

    // Consumer参数
    public static final String ENABLE_AUTO_COMMIT = "true";
    public static final String AUTO_COMMIT_INTERVAL_MS = "1000";

    // Procedure参数
    public static final int RETRIES = 0;
    public static final int BATCH_SIZE = 16384;
    public static final int LINGER_MS = 1;

}
